package com.jy.oms.framework.asyn.task.queue.database.service.impl;

import com.jy.oms.framework.asyn.task.queue.database.dao.SysTaskQueueDao;
import com.jy.oms.framework.asyn.task.queue.database.entity.SysTaskQuery;
import com.jy.oms.framework.asyn.task.queue.database.entity.SysTaskQueue;
import com.jy.oms.framework.asyn.task.queue.database.service.ISysTaskQueueService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class SysTaskServiceQueueImpl implements ISysTaskQueueService {

    @Autowired
    private SysTaskQueueDao sysTaskQueueDao;

    @Override
    public int querySysTaskCount(SysTaskQuery sysTaskQuery, String taskQueueName) {
        return this.sysTaskQueueDao.querySysTaskCount(sysTaskQuery, taskQueueName);
    }

    @Override
    public List<SysTaskQueue> querySysTaskList(SysTaskQuery sysTaskQuery, String taskQueueName) {
        return this.sysTaskQueueDao.querySysTaskList(sysTaskQuery, taskQueueName);
    }

    @Override
    public int insertSysTask(SysTaskQueue sysTask, String taskQueueName) {
        return this.sysTaskQueueDao.insertSysTask(sysTask, taskQueueName);
    }

    @Override
    public int insertSysTaskList(List<SysTaskQueue> sysTasks, String taskQueueName) {
        return this.sysTaskQueueDao.insertSysTaskList(sysTasks, taskQueueName);
    }

    @Override
    public int updateById(SysTaskQueue sysTask, String taskQueueName) {
        return this.sysTaskQueueDao.updateById(sysTask, taskQueueName);
    }

    @Override
    public int updateBatchById(List<SysTaskQueue> sysTasks, String taskQueueName) {
        return this.sysTaskQueueDao.updateBatchById(sysTasks, taskQueueName);
    }

}
